package com.easipass.framework.eirframeworkcore;

import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;

@FeignClient(value = "stream")
public interface StreamFeignService {
    @RequestMapping(value = "/send/sink/{dest}", method = RequestMethod.POST)
    String putKafkaMsg(@PathVariable("dest") String dest,
                       @RequestParam(value = "msg") String msg,
                       @RequestParam(value = "name") String name);
}
